package com.jugheadzhou.streamproducer.service;

import org.springframework.cloud.stream.annotation.EnableBinding;
import org.springframework.cloud.stream.messaging.Source;
import org.springframework.messaging.support.MessageBuilder;

import javax.annotation.Resource;

/**
 * 默认的传输通道方式
 * @EnableBinding 这个注解给我们绑定消息通道的，Source是Stream给我们提供的，
 * 可以点进去看源码，可以看到output和input,这和配置文件中的output，input对应的。
 *
 * @author jugheadzhou
 * @date 2021-09-28
 */
//@EnableBinding(Source.class)
public class DefaultService {

//    @Resource
//    private Source source;
//
//    public void sendMsg(String msg){
//        source.output().send(MessageBuilder.withPayload(msg).build());
//    }

}
